e904c3fb44db4bee942c4290e76ad4745fd172de,fabric/fabric-core/src/main/java/io/fabric8/internal/ZooKeeperClusterServiceImpl.java,ZooKeeperClusterServiceImpl,createCluster,#List#CreateEnsembleOptions#,147
Before Change
// configure this server in the ensemble
String ensembleMemberProfile = profileRegistry.get().getProfile(version, "fabric-ensemble-" + newClusterId + "-" + Integer.toString(index), true);
profileRegistry.get().setProfileAttribute(version, ensembleMemberProfile, "hidden", "true");
profileRegistry.get().setProfileAttribute(version, ensembleMemberProfile, "parents", ensembleProfile);
String port1 = Integer.toString(findPort(usedPorts, ip, mapPortToRange(Ports.DEFAULT_ZOOKEEPER_SERVER_PORT, minimumPort, maximumPort)));
After Change
IllegalStateAssertion.assertFalse(profileRegistry.get().hasProfile(versionId, profileId), "Profile already exists: " + versionId + "/" + profileId);
String ensembleProfileId = profileRegistry.get().getProfile(versionId, profileId, true);
profileRegistry.get().setProfileAttribute(versionId, ensembleProfileId, "abstract", "true");
profileRegistry.get().setProfileAttribute(versionId, ensembleProfileId, "hidden", "true");
Properties ensembleProperties = new Properties();
ensembleProperties.put("tickTime", String.valueOf(options.getZooKeeperServerTickTime()));
ensembleProperties.put("initLimit", String.valueOf(options.getZooKeeperServerInitLimit()));
ensembleProperties.put("syncLimit", String.valueOf(options.getZooKeeperServerSyncLimit()));
ensembleProperties.put("dataDir", options.getZooKeeperServerDataDir() + File.separator + newClusterId);
int index = 1;
String connectionUrl = "";
String realConnectionUrl = "";
String containerList = "";
for (String container : containers) {
String ip = getSubstitutedPath(curator.get(), ZkPath.CONTAINER_IP.getPath(container));
String minimumPort = String.valueOf(Ports.MIN_PORT_NUMBER);
String maximumPort = String.valueOf(Ports.MAX_PORT_NUMBER);
String bindAddress = "0.0.0.0";
if (exists(curator.get(), ZkPath.CONTAINER_PORT_MIN.getPath(container)) != null) {
minimumPort = getSubstitutedPath(curator.get(), ZkPath.CONTAINER_PORT_MIN.getPath(container));
}
if (exists(curator.get(), ZkPath.CONTAINER_PORT_MAX.getPath(container)) != null) {
maximumPort = getSubstitutedPath(curator.get(), ZkPath.CONTAINER_PORT_MAX.getPath(container));
}
if (exists(curator.get(), ZkPath.CONTAINER_BINDADDRESS.getPath(container)) != null) {
bindAddress = getSubstitutedPath(curator.get(), ZkPath.CONTAINER_BINDADDRESS.getPath(container));
}
String ensembleMemberConfigName = "io.fabric8.zookeeper.server-" + newClusterId + ".properties";
Properties ensembleMemberProperties = new Properties();
// configure this server in the ensemble
profileId = "fabric-ensemble-" + newClusterId + "-" + index;
IllegalStateAssertion.assertFalse(profileRegistry.get().hasProfile(versionId, profileId), "Profile already exists: " + versionId + "/" + profileId);
String ensembleMemberProfileId = profileRegistry.get().getProfile(versionId, profileId, true);
profileRegistry.get().setProfileAttribute(versionId, ensembleMemberProfileId, "hidden", "true");
profileRegistry.get().setProfileAttribute(versionId, ensembleMemberProfileId, "parents", ensembleProfileId);